package com.czl.myRabbitMq.commom;

import com.czl.myRabbitMq.mqServer.core.BasicProperties;

import java.io.IOException;

//这里的Consume为一个函数式接口 也就是回调函数 方便我们
// 在拿到消息之后使用lambda表达式进行操作
@FunctionalInterface
public interface Consume {
    void delivery(String consumeTag, BasicProperties basicProperties, byte[] body) throws IOException;
}
